package com.rxjava.jdbc;

import java.util.ArrayList;
import java.util.List;

import rx.Observable;

public class Controller {
	public RxJdbcService service = new RxJdbcService();
	
	public void service(){
		String str = null;
		List<String> result = new ArrayList<String>();
		service.query().flatMap(list -> Observable.from(list)).first().subscribe((s) -> {
			System.out.println(s);
			result.add(s);
		});
	}
}
